:art: everyday_continue_send_user_coupon
huangqimin001
2 changed files with 9 additions and 4 deletions
+ 8
- 3
commands/management/commands/everyday_continue_send_user_coupon.py
@@ -3,11 +3,11 @@ |
||
| 3 | 3 |
import logging |
| 4 | 4 |
|
| 5 | 5 |
from django_six import CompatibilityBaseCommand |
| 6 |
+from TimeConvert import TimeConvert as tc |
|
| 6 | 7 |
|
| 7 | 8 |
from account.models import UserInfo |
| 8 |
-from coupon.models import CouponInfo, UserCouponInfo |
|
| 9 |
-from member.models import RightInfo |
|
| 10 |
-from TimeConvert import TimeConvert as tc |
|
| 9 |
+from utils.redis.connect import r |
|
| 10 |
+from utils.redis.rkeys import MEMBER_SEND_COUPON_LIST2 |
|
| 11 | 11 |
|
| 12 | 12 |
|
| 13 | 13 |
logger = logging.getLogger('console')
|
@@ -16,3 +16,8 @@ logger = logging.getLogger('console')
|
||
| 16 | 16 |
class Command(CompatibilityBaseCommand): |
| 17 | 17 |
def handle(self, *args, **options): |
| 18 | 18 |
users = UserInfo.objects.filter(coupon_expire_at__lte=tc.utc_datetime(), status=True) |
| 19 |
+ # 发放会员权益 |
|
| 20 |
+ for user in users: |
|
| 21 |
+ r.rpushjson(MEMBER_SEND_COUPON_LIST2, {
|
|
| 22 |
+ 'user_id': user.user_id, |
|
| 23 |
+ }) |
+ 1
- 1
integral/models.py
@@ -5,7 +5,7 @@ from django.utils.translation import ugettext_lazy as _ |
||
| 5 | 5 |
from django_models_ext import BaseModelMixin, upload_file_path, upload_file_url, upload_path |
| 6 | 6 |
from TimeConvert import TimeConvert as tc |
| 7 | 7 |
|
| 8 |
-from mch.models import ModelInfo, DistributorInfo |
|
| 8 |
+from mch.models import DistributorInfo, ModelInfo |
|
| 9 | 9 |
from sales.models import SalesResponsibilityInfo |
| 10 | 10 |
from utils.qiniucdn import qiniu_file_url |
| 11 | 11 |
|